package com.javachmapi.springbootjsoup.log;

import com.javachmapi.springbootjsoup.util.SpringUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.transaction.TransactionException;

/**
 * @author songlijun
 * @desc: 这个是公众号抓取产品的日志存储类
 */
@Slf4j
public class PeptileTaskLog {
    /**
     * 创建数据表存储日志
     * @param text
     * @param state
     * @throws TransactionException
     */
    public static void createTableLog(String text, int state) {
        //保存日志
        String sql = "insert into reptile_create_table_log (text,state,create_date) values (?,?,now())";
        SpringUtil.getBean(JdbcTemplate.class).update(sql,new Object[]{text, state});
    }

    /**
     * 通用日志存储方法
     * @param biz 公众号标识
     * @param logs 日志
     * @param state 执行状态
     */
    public static void pullProductLog(String biz, String logs,int count,String state) throws TransactionException {
        log.info("正在保存{}日志,一共保存了{}条数据！",biz,count);
        String sql = "insert into reptile_log (biz,logs,count,create_date,state) values (?,?,?,now(),?)";
        SpringUtil.getBean(JdbcTemplate.class).update(sql,new Object[]{biz,logs, count,state});
    }
}
